package com.shujia.hdfs;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;

/**
 *  配置项优先级：
 *      代码中的配置参数 > resource中的配置参数 > Hadoop服务中的配置参数
 */
public class Code03ReplicationOpera {
    public static void main(String[] args) throws URISyntaxException, IOException, InterruptedException {
        Configuration conf = new Configuration();
//        方式二：
        conf.set("dfs.replication","1");

        FileSystem fileSystem = FileSystem.get(new URI("hdfs://master:9000"), conf, "root");

            // 修改副本数方式一：
//        fileSystem.setReplication(new Path("/data/aaa.txt"),  new Integer(1).shortValue() );
        fileSystem.copyFromLocalFile(new Path("D:\\HadoopCode\\data\\aaa.txt"),new Path("/data/hhh.txt"));

        fileSystem.close();
    }
}
